package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.MarketActivityConstant;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Service;

/**
 * @version v1.0
 * 市场管理 消息队列
 * @return: $
 * @auther: youli.chen
 * @date: $ $
 * @since v1.0
 */
@Service("marketActivityConsumerBinder")
public interface MarketActivityConsumerBinder {

    /**
     * 线索
     */
    @Input(MarketActivityConstant.CLUE_INPUT)
    SubscribableChannel clueInput();

    @Input(MarketActivityConstant.CLUE_HANDOVER_INPUT)
    SubscribableChannel clueHandoverInput();

    @Input(MarketActivityConstant.CLUE_DISTRIBUTION_INPUT)
    SubscribableChannel clueDistributionInput();
}
